package cn.com.zetatech.loader.common.service;

/**
 * @author zhengbs
 */
public interface ResolverStoreService {

    /**
     * 保存数据时调用
     * 1. 发送数据到kafka
     * 2. 添加数据状态监控
     * @param topic  发送的kafka topic
     * @param data   待保存的数据json
     * @param fileId 解析文件ID
     * @param resolverCompleted 文件是否解析完
     * @return
     */
    boolean dataStore(String topic, String data, String fileId, boolean resolverCompleted, String complateInfo);
}
